do {
    // Test paginated full sync
    let allProducts = try await loadAllProducts(syncRemote: syncRemote, siteID: siteID)
    let allVariations = try await loadAllProductVariations(syncRemote: syncRemote, siteID: siteID)
    print("Fetched \(allProducts.count) products and \(allVariations.count) variations for siteID \(siteID)")
}

private func loadAllProducts(syncRemote: POSCatalogSyncRemote, siteID: Int64) async throws -> [POSProduct] {
    let firstPage = try await syncRemote.loadProducts(siteID: siteID, pageNumber: 1)
    print("Total products: \(firstPage.totalItems ?? 0)")    
    guard let totalItems = firstPage.totalItems, totalItems > 0 else {
        return []
    }

    // Calculate total pages needed (page size is 100 as per constants)
    let pageSize = 100
    let totalPages = (totalItems + pageSize - 1) / pageSize // Ceiling division
    print("Total product pages to fetch: \(totalPages)")
    
    // Start with products from first page
    var allProducts = firstPage.items
    
    guard totalPages > 1 else {
        return allProducts
    }
    
    // Fetch remaining pages in parallel batches
    let remainingPages = Array(2...totalPages)
    let batchSize = 5 // Process 5 pages in parallel at a time
    
    for batch in remainingPages.chunked(into: batchSize) {
        let batchResults = try await withThrowingTaskGroup(of: (Int, PagedItems<POSProduct>).self) { group in
            // Add tasks for each page in the batch
            for pageNumber in batch {
                group.addTask {
                    print("🔄 Fetching products page \(pageNumber)/\(totalPages)")
                    let result = try await syncRemote.loadProducts(siteID: siteID, pageNumber: pageNumber)
                    return (pageNumber, result)
                }
            }
            
            // Collect results
            var results: [(Int, PagedItems<POSProduct>)] = []
            for try await result in group {
                results.append(result)
            }
            
            return results
        }
        
        // Sort results by page number to maintain order
        let sortedResults = batchResults.sorted { $0.0 < $1.0 }
        
        // Add all products from this batch in order
        for (_, pageResult) in sortedResults {
            allProducts.append(contentsOf: pageResult.items)
        }
        
        print("Completed batch, total products loaded: \(allProducts.count)")
    }
    
    print("✅ Products sync complete: \(allProducts.count) products loaded")
    return allProducts
}

private func loadAllProductVariations(syncRemote: POSCatalogSyncRemote, siteID: Int64) async throws -> [POSProductVariation] {
    // Make first request to get total count
    let firstPage = try await syncRemote.loadProductVariations(siteID: siteID, pageNumber: 1)
    print("Total variations: \(firstPage.totalItems ?? 0)")
    
    guard let totalItems = firstPage.totalItems, totalItems > 0 else {
        return []
    }
    
    // Calculate total pages needed (page size is 100 as per constants)
    let pageSize = 100
    let totalPages = (totalItems + pageSize - 1) / pageSize // Ceiling division
    print("Total pages to fetch: \(totalPages)")
    
    // Start with variations from first page
    var allVariations = firstPage.items
    
    guard totalPages > 1 else {
        return allVariations
    }
    
    // Fetch remaining pages in parallel batches
    let remainingPages = Array(2...totalPages)
    let batchSize = 5 // Process 5 pages in parallel at a time
    
    for batch in remainingPages.chunked(into: batchSize) {
        let batchResults = try await withThrowingTaskGroup(of: (Int, PagedItems<POSProductVariation>).self) { group in
            // Add tasks for each page in the batch
            for pageNumber in batch {
                group.addTask {
                    print("🔄 Fetching variations page \(pageNumber)/\(totalPages)")
                    let result = try await syncRemote.loadProductVariations(siteID: siteID, pageNumber: pageNumber)
                    return (pageNumber, result)
                }
            }
            
            // Collect results
            var results: [(Int, PagedItems<POSProductVariation>)] = []
            for try await result in group {
                results.append(result)
            }
            return results
        }
        
        // Sort results by page number to maintain order
        let sortedResults = batchResults.sorted { $0.0 < $1.0 }
        
        // Add all variations from this batch in order
        for (_, pageResult) in sortedResults {
            allVariations.append(contentsOf: pageResult.items)
        }
        
        print("Completed batch, total variations loaded: \(allVariations.count)")
    }
    
    print("✅ Variations sync complete: \(allVariations.count) variations loaded")
    return allVariations
}